package jdbc_demo;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class my {


    public static int  compare(String user_id,String user_password) {
        int state = 0;
        try {
            Class.forName("com.mysql.cj.jdbc.Driver");     //加载MYSQL JDBC驱动程序
            System.out.println("Success loading Mysql Driver!");
        }
        catch (Exception e) {
            System.out.print("Error loading Mysql Driver!");
            e.printStackTrace();
        }

        try { //连接URL为   jdbc:mysql//服务器地址/数据库名  ，后面的2个参数分别是登陆用户名和密码
            Connection connect = DriverManager.getConnection("jdbc:mysql://localhost:3306/talknewsdatabase","root","123456");

            System.out.println("Success connect Mysql server!");
            Statement stmt = connect.createStatement();
            ResultSet rs = stmt.executeQuery("select * from user");
            //user 表的名称
            while (rs.next()) {
//                System.out.println(rs.getString("user_id")+" "+rs.getString("user_password"));//调试

                if( user_id.equals(rs.getString("user_id")) &&
                        user_password.equals(rs.getString("user_password"))){
                    state = 1;
                }
            }
//            System.out.println(state);//测试 1为正确通过验证
        }
        catch (Exception e) {
            System.out.print("get data error!");
            e.printStackTrace();
        }
        return state;
    }

}